#if !defined(__APP_MQTT_H__)
#define __APP_MQTT_H__
#define ADDRESS "tcp://192.168.55.49:1883"
#define CLIENTID "da0fbe2f-b4dc-4b1d-a9a3-b730495122d4"
#define TOPIC_PULL "pull"
#define TOPIC_PUSH "push"
#define PAYLOAD "Hello World!"
#define QOS 1
#define TIMEOUT 10000L
/**
 * @brief 初始化mqtt客户端
 */

int app_mqtt_init(void);

/**
 * @brief 关闭mqtt客户端
 */

void app_mqtt_close(void);

/**
 * @brief 发送消息
 */

int app_mqtt_send(char *json);

/**
 * @brief 注册接收处理接收到的消息的回调函数
 */

void app_mqtt_registerRecvCallback(int callback(char *json));

#endif // __APP_MQTT_H



